from pandas import DataFrame

def run(source: DataFrame, param_dict: dict):
    parquet_path = param_dict["path"]
    # hdfs_path = param_dict["hive_table"]
    compression = None
    if "compression" in param_dict:
        compression = param_dict["compression"]
    source.to_parquet(parquet_path,compression=compression)